import { createClient } from "redis";

// const client = await createClient({ url: "redis://localhost:6666" }).connect();

// await client.set("name", "jiangwen");

// let value = await client.get("name");

// let flag = await client.exists("name");
// console.log(flag);

// await client.expire("name", 10);
// const ttl = await client.ttl("name");

// await client.hSet("person", "name", "jiangwen");
// await client.hSet("person", "age", 30);
// const obj = await client.hGetAll("person");
// console.log(obj);
// client.disconnect();

// 每次访问服务器，根据当前的生辰八字 生成一个html页面。 先监听消息
// 后续有更新了 需要通知我来更新

// 客户端之间来相互通知

let client1 = await createClient({ url: "redis://localhost:6666" }).connect();
let client2 = await createClient({ url: "redis://localhost:6666" }).connect();

await client1.subscribe("room1", (message) => {
  console.log(message); // 更新操作
});

setTimeout(() => {
  client2.publish("room1", "abc");
}, 1000);

// 服务端会基于key value 的形式封装一套增删改查用于存储数据

// redis 是内存数据库
